🎖️GitЯра🎖️ - /page/blob.mu

T8b949e/*

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787kotlinx.coroutines.CancellationException

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.Job

Tff7b72import T7ee787kotlinx.coroutines.delay

Tff7b72import T7ee787kotlinx.coroutines.flow.first

Tff7b72import T7ee787kotlinx.coroutines.flow.launchIn

Tff7b72import T7ee787kotlinx.coroutines.flow.onEach

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787kotlinx.coroutines.sync.Mutex

Tff7b72import T7ee787kotlinx.coroutines.sync.withLock

Tff7b72import T7ee787org.koin.core.annotation.Named

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch

Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis

Tff7b72import T7ee787org.meshtastic.core.common.util.nowSeconds

Tff7b72import T7ee787org.meshtastic.core.model.ConnectionState

Tff7b72import T7ee787org.meshtastic.core.model.DeviceType

Tff7b72import T7ee787org.meshtastic.core.model.TelemetryType

Tff7b72import T7ee787org.meshtastic.core.repository.AppWidgetUpdater

Tff7b72import T7ee787org.meshtastic.core.repository.CommandSender

Tff7b72import T7ee787org.meshtastic.core.repository.DataPair

Tff7b72import T7ee787org.meshtastic.core.repository.HandshakeConstants

Tff7b72import T7ee787org.meshtastic.core.repository.HistoryManager

Tff7b72import T7ee787org.meshtastic.core.repository.MeshConnectionManager

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLocationManager

Tff7b72import T7ee787org.meshtastic.core.repository.MeshNotificationManager

Tff7b72import T7ee787org.meshtastic.core.repository.MeshWorkerManager

Tff7b72import T7ee787org.meshtastic.core.repository.MqttManager

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.NodeRepository

Tff7b72import T7ee787org.meshtastic.core.repository.PacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository

Tff7b72import T7ee787org.meshtastic.core.repository.PlatformAnalytics

Tff7b72import T7ee787org.meshtastic.core.repository.RadioConfigRepository

Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService

Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository

Tff7b72import T7ee787org.meshtastic.core.repository.SessionManager

Tff7b72import T7ee787org.meshtastic.core.repository.UiPrefs

Tff7b72import T7ee787org.meshtastic.proto.AdminMessage

Tff7b72import T7ee787org.meshtastic.proto.Config

Tff7b72import T7ee787org.meshtastic.proto.Telemetry

Tff7b72import T7ee787org.meshtastic.proto.ToRadio

Tff7b72import T7ee787kotlin.time.Duration

Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds

Tff7b72import T7ee787kotlin.time.Duration.Companion.seconds

Tff7b72import T7ee787kotlin.time.DurationUnit

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)

Tf0883e@Single

Tff7b72class T56d364MeshConnectionManagerImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3radioInterfaceServiceTb4b4b4: Te6edf3RadioInterfaceServiceTb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceRepositoryTb4b4b4: Te6edf3ServiceRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceNotificationsTb4b4b4: Te6edf3MeshNotificationManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3uiPrefsTb4b4b4: Te6edf3UiPrefsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3packetHandlerTb4b4b4: Te6edf3PacketHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeRepositoryTb4b4b4: Te6edf3NodeRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3locationManagerTb4b4b4: Te6edf3MeshLocationManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3mqttManagerTb4b4b4: Te6edf3MqttManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3historyManagerTb4b4b4: Te6edf3HistoryManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3radioConfigRepositoryTb4b4b4: Te6edf3RadioConfigRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3commandSenderTb4b4b4: Te6edf3CommandSenderTb4b4b4,

Tff7b72private Tff7b72val Te6edf3sessionManagerTb4b4b4: Te6edf3SessionManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3analyticsTb4b4b4: Te6edf3PlatformAnalyticsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3packetRepositoryTb4b4b4: Te6edf3PacketRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3workerManagerTb4b4b4: Te6edf3MeshWorkerManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3appWidgetUpdaterTb4b4b4: Te6edf3AppWidgetUpdaterTb4b4b4,

Tff7b72private Tff7b72val Te6edf3heartbeatSenderTb4b4b4: Te6edf3DataLayerHeartbeatSenderTb4b4b4,

Tf0883e@NamedTb4b4b4(Ta5d6ff"Ta5d6ffServiceScopeTa5d6ff"Tb4b4b4) Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3MeshConnectionManager Tb4b4b4{

T8b949e/**

* Serializes [onConnectionChanged] to prevent TOCTOU races when multiple coroutines emit state transitions

* concurrently (e.g. flow collector vs. sleep-timeout coroutine).

*/

Tff7b72private Tff7b72val Te6edf3connectionMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72var Te6edf3preHandshakeJobTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

Tff7b72private Tff7b72var Te6edf3sleepTimeoutTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

Tff7b72private Tff7b72var Te6edf3locationRequestsJobTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

Tff7b72private Tff7b72var Te6edf3handshakeTimeoutTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

Tff7b72private Tff7b72var Te6edf3connectTimeMsec Tff7b72= T79c0ff0L

Tff7b72private Tff7b72var Te6edf3connectionRestored Tff7b72= Tff7b72false

Tff7b72init Tb4b4b4{

T8b949e// Bridge transport-level state into the canonical app-level state.

T8b949e// This is the ONLY consumer of RadioInterfaceService.connectionState — it applies

T8b949e// light-sleep policy and handshake awareness before writing to ServiceRepository.

Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3onEachTb4b4b4(Tff7b72::Te6edf3onRadioConnectionStateTb4b4b4)Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)

T8b949e// Ensure notification title and content stay in sync with state changes

Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3updateStatusNotificationTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Tff7b72try Tb4b4b4{

Te6edf3appWidgetUpdaterTb4b4b4.Te6edf3updateAllTb4b4b4(Tb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffFailed to kickstart LocalStatsWidgetTa5d6ff" Tb4b4b4}

Tb4b4b4}

Te6edf3nodeRepositoryTb4b4b4.Te6edf3myNodeInfo

Tb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3myNodeEntity Tff7b72-Tff7b72>

Te6edf3locationRequestsJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3myNodeEntity Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3locationRequestsJob Tff7b72=

Te6edf3uiPrefs

Tb4b4b4.Te6edf3shouldProvideNodeLocationTb4b4b4(Te6edf3myNodeEntityTb4b4b4.Te6edf3myNodeNumTb4b4b4)

Tb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3shouldProvide Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3shouldProvideTb4b4b4) Tb4b4b4{

Te6edf3locationManagerTb4b4b4.Te6edf3startTb4b4b4(Te6edf3scopeTb4b4b4) Tb4b4b4{ Te6edf3pos Tff7b72-Tff7b72> Te6edf3commandSenderTb4b4b4.Te6edf3sendPositionTb4b4b4(Te6edf3posTb4b4b4) Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3locationManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)

Tb4b4b4}

T8b949e/**

* Bridges a transport-level [ConnectionState] into the canonical app-level state.

*

* Applies light-sleep policy (power-saving / router role) to decide whether a [ConnectionState.DeviceSleep] event

* should be surfaced as sleep or as a full disconnect, then delegates to [onConnectionChanged] for the actual state

* transition.

*/

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffonRadioConnectionStateTb4b4b4(Te6edf3newStateTb4b4b4: Te6edf3ConnectionStateTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3localConfig Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3isRouter Tff7b72= Te6edf3localConfigTb4b4b4.Te6edf3deviceTff7b72?.Te6edf3role Tff7b72=Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3DeviceConfigTb4b4b4.Te6edf3RoleTb4b4b4.Te6edf3ROUTER

Tff7b72val Te6edf3lsEnabled Tff7b72= Te6edf3localConfigTb4b4b4.Te6edf3powerTff7b72?.Te6edf3is_power_saving Tff7b72=Tff7b72= Tff7b72true Tff7b72|Tff7b72| Te6edf3isRouter

Tff7b72val Te6edf3effectiveState Tff7b72=

Tff7b72when Tb4b4b4(Te6edf3newStateTb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected Tff7b72-Tff7b72> Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3lsEnabledTb4b4b4) Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep Tff7b72else Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Connecting Tff7b72-Tff7b72> Te6edf3ConnectionStateTb4b4b4.Te6edf3Connecting

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected Tff7b72-Tff7b72> Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected

Tb4b4b4}

Te6edf3onConnectionChangedTb4b4b4(Te6edf3effectiveStateTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffonConnectionChangedTb4b4b4(Te6edf3cTb4b4b4: Te6edf3ConnectionStateTb4b4b4) Tff7b72= Te6edf3connectionMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Tff7b72val Te6edf3current Tff7b72= Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3value

Tff7b72if Tb4b4b4(Te6edf3current Tff7b72=Tff7b72= Te6edf3cTb4b4b4) Tff7b72returnTf0883e@withLock

T8b949e// If the transport reports 'Connected', but we are already in the middle of a handshake (Connecting)

Tff7b72if Tb4b4b4(Te6edf3c Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected Tff7b72&Tff7b72& Te6edf3current Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffIgnoring redundant transport connection signal while handshake is in progressTa5d6ff" Tb4b4b4}

Tff7b72returnTf0883e@withLock

Tb4b4b4}

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffonConnectionChanged: Tffd700$Te6edf3currentTa5d6ff -> Tffd700$Te6edf3cTa5d6ff" Tb4b4b4}

Te6edf3sleepTimeoutTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3sleepTimeout Tff7b72= Tff7b72null

Te6edf3preHandshakeJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3preHandshakeJob Tff7b72= Tff7b72null

Te6edf3handshakeTimeoutTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3handshakeTimeout Tff7b72= Tff7b72null

Tff7b72when Tb4b4b4(Te6edf3cTb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Connecting Tff7b72-Tff7b72> Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4)

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected Tff7b72-Tff7b72> Te6edf3handleConnectedTb4b4b4(Tb4b4b4)

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep Tff7b72-Tff7b72> Te6edf3handleDeviceSleepTb4b4b4(Tb4b4b4)

Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected Tff7b72-Tff7b72> Te6edf3handleDisconnectedTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleConnectedTb4b4b4(Tb4b4b4) Tb4b4b4{

T8b949e// Track whether this connection was restored from device sleep (vs. a fresh connect),

T8b949e// matching Apple's "connectionRestored" attribute for cross-platform DataDog parity.

Te6edf3connectionRestored Tff7b72= Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3value Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep

T8b949e// The service state remains 'Connecting' until config is fully loaded

Tff7b72if Tb4b4b4(Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3value Tff7b72!Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectedTb4b4b4) Tb4b4b4{

Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4)

Tb4b4b4}

Te6edf3connectTimeMsec Tff7b72= Te6edf3nowMillis

T8b949e// Send a wake-up heartbeat before the config request. The firmware may be in a

T8b949e// power-saving state where the NimBLE callback context needs warming up. The 100ms

T8b949e// delay ensures the heartbeat BLE write is enqueued before the want_config_id

T8b949e// (sendToRadio is fire-and-forget through async coroutine launches).

Te6edf3preHandshakeJob Tff7b72=

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Te6edf3heartbeatSenderTb4b4b4.Te6edf3sendHeartbeatTb4b4b4(Ta5d6ff"Ta5d6ffpre-handshakeTa5d6ff"Tb4b4b4)

Te6edf3delayTb4b4b4(Te6edf3PRE_HANDSHAKE_SETTLE_MSTb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffStarting mesh handshake (Stage 1)Ta5d6ff" Tb4b4b4}

Te6edf3startConfigOnlyTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffstartHandshakeStallGuardTb4b4b4(Te6edf3stageTb4b4b4: Tffa657IntTb4b4b4, Te6edf3timeoutTb4b4b4: Te6edf3DurationTb4b4b4, Te6edf3actionTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4) Tb4b4b4{

Te6edf3handshakeTimeoutTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3handshakeTimeout Tff7b72=

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Te6edf3delayTb4b4b4(Te6edf3timeoutTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3value Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4) Tb4b4b4{

T8b949e// Attempt one retry. Note: the firmware silently drops identical consecutive

T8b949e// writes (per-connection dedup). If the first want_config_id was received and

T8b949e// the stall is on our side, the retry will be dropped and the reconnect below

T8b949e// will trigger instead — which is the right recovery in that case.

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{

Ta5d6ff"Ta5d6ffHandshake stall detected at Stage Tffd700$Te6edf3stageTa5d6ff — retrying, then reconnecting if still stalledTa5d6ff"

Tb4b4b4}

Te6edf3actionTb4b4b4(Tb4b4b4)

Te6edf3delayTb4b4b4(Te6edf3HANDSHAKE_RETRY_TIMEOUTTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3value Tff7b72is Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3e Tb4b4b4{ Ta5d6ff"Ta5d6ffHandshake still stalled after retry, forcing reconnectTa5d6ff" Tb4b4b4}

Te6edf3onConnectionChangedTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fftearDownConnectionTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3packetHandlerTb4b4b4.Te6edf3stopPacketQueueTb4b4b4(Tb4b4b4)

Te6edf3sessionManagerTb4b4b4.Te6edf3clearAllTb4b4b4(Tb4b4b4) T8b949e// Prevent stale per-node passkeys on reconnect.

Te6edf3locationManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)

Te6edf3mqttManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleDeviceSleepTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleepTb4b4b4)

Te6edf3tearDownConnectionTb4b4b4(Tb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3connectTimeMsec Tff7b72!Tff7b72= T79c0ff0LTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3now Tff7b72= Te6edf3nowMillis

Tff7b72val Te6edf3duration Tff7b72= Te6edf3now Tff7b72- Te6edf3connectTimeMsec

Te6edf3connectTimeMsec Tff7b72= T79c0ff0L

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(

Te6edf3EVENT_CONNECTED_SECONDSTb4b4b4,

Te6edf3DataPairTb4b4b4(Te6edf3EVENT_CONNECTED_SECONDSTb4b4b4, Te6edf3durationTb4b4b4.Te6edf3millisecondsTb4b4b4.Te6edf3toDoubleTb4b4b4(Te6edf3DurationUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Te6edf3sleepTimeout Tff7b72=

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72try Tb4b4b4{

Tff7b72val Te6edf3localConfig Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3rawTimeout Tff7b72= Tb4b4b4(Te6edf3localConfigTb4b4b4.Te6edf3powerTff7b72?.Te6edf3ls_secs Tff7b72?: T79c0ff0Tb4b4b4) Tff7b72+ Te6edf3DEVICE_SLEEP_TIMEOUT_SECONDS

T8b949e// Cap the timeout so routers or power-saving configs (ls_secs=3600) don't

T8b949e// leave the UI stuck in DeviceSleep for over an hour.

Tff7b72val Te6edf3timeout Tff7b72= Te6edf3rawTimeoutTb4b4b4.Te6edf3coerceAtMostTb4b4b4(Te6edf3MAX_SLEEP_TIMEOUT_SECONDSTb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffWaiting for sleeping device, timeout=Tffd700$Te6edf3timeoutTa5d6ff secs (raw=Tffd700$Te6edf3rawTimeoutTa5d6ff)Ta5d6ff" Tb4b4b4}

Te6edf3delayTb4b4b4(Te6edf3timeoutTb4b4b4.Te6edf3secondsTb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffDevice timed out, setting disconnectedTa5d6ff" Tb4b4b4}

Te6edf3onConnectionChangedTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3_Tb4b4b4: Te6edf3CancellationExceptionTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffdevice sleep timeout cancelledTa5d6ff" Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleDisconnectedTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)

Te6edf3tearDownConnectionTb4b4b4(Tb4b4b4)

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(

Te6edf3EVENT_MESH_DISCONNECTTb4b4b4,

Te6edf3DataPairTb4b4b4(Te6edf3KEY_NUM_NODESTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4,

Te6edf3DataPairTb4b4b4(Te6edf3KEY_NUM_ONLINETb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3count Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3isOnline Tb4b4b4}Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(Te6edf3EVENT_NUM_NODESTb4b4b4, Te6edf3DataPairTb4b4b4(Te6edf3KEY_NUM_NODESTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffstartConfigOnlyTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3action Tff7b72= Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3startHandshakeStallGuardTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3HANDSHAKE_TIMEOUT_STAGE1Tb4b4b4, Te6edf3actionTb4b4b4)

Te6edf3actionTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffstartNodeInfoOnlyTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3action Tff7b72= Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3startHandshakeStallGuardTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3HANDSHAKE_TIMEOUT_STAGE2Tb4b4b4, Te6edf3actionTb4b4b4)

Te6edf3actionTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonRadioConfigLoadedTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72val Te6edf3queuedPackets Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3getQueuedPacketsTb4b4b4(Tb4b4b4)

Te6edf3queuedPacketsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

Tff7b72try Tb4b4b4{

Te6edf3workerManagerTb4b4b4.Te6edf3enqueueSendMessageTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffFailed to enqueue queued packet workerTa5d6ff" Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffonNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3handshakeTimeoutTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3handshakeTimeout Tff7b72= Tff7b72null

Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: T79c0ff0

T8b949e// Set device time now that the full node picture is ready. Sending this during Stage 1

T8b949e// (onRadioConfigLoaded) introduced GATT write contention with the Stage 2 node-info burst.

Te6edf3commandSenderTb4b4b4.Te6edf3sendAdminTb4b4b4(Te6edf3myNodeNumTb4b4b4) Tb4b4b4{ Te6edf3AdminMessageTb4b4b4(Te6edf3set_time_only Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

T8b949e// Proactively seed the session passkey. The firmware embeds session_passkey in every

T8b949e// admin *response* (wantResponse=true), but set_time_only has no response. A get_owner

T8b949e// request is the lightest way to trigger a response and populate the passkey cache so

T8b949e// that subsequent write operations don't fail with ADMIN_BAD_SESSION_KEY.

Te6edf3commandSenderTb4b4b4.Te6edf3sendAdminTb4b4b4(Te6edf3myNodeNumTb4b4b4, Te6edf3wantResponse Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4{ Te6edf3AdminMessageTb4b4b4(Te6edf3get_owner_request Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4}

T8b949e// Start MQTT if enabled

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72val Te6edf3moduleConfig Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3moduleConfigFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Te6edf3mqttManagerTb4b4b4.Te6edf3startProxyTb4b4b4(

Te6edf3moduleConfigTb4b4b4.Te6edf3mqttTff7b72?.Te6edf3enabled Tff7b72=Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3moduleConfigTb4b4b4.Te6edf3mqttTff7b72?.Te6edf3proxy_to_client_enabled Tff7b72=Tff7b72= Tff7b72trueTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Te6edf3reportConnectionTb4b4b4(Tb4b4b4)

T8b949e// Request history

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72val Te6edf3moduleConfig Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3moduleConfigFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Te6edf3moduleConfigTb4b4b4.Te6edf3store_forwardTff7b72?.Te6edf3let Tb4b4b4{

Te6edf3historyManagerTb4b4b4.Te6edf3requestHistoryReplayTb4b4b4(Ta5d6ff"Ta5d6ffonNodeDbReadyTa5d6ff"Tb4b4b4, Te6edf3myNodeNumTb4b4b4, Tffa657itTb4b4b4, Ta5d6ff"Ta5d6ffUnknownTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// Request immediate LocalStats and DeviceMetrics update on connection with proper request IDs

Te6edf3commandSenderTb4b4b4.Te6edf3requestTelemetryTb4b4b4(Te6edf3commandSenderTb4b4b4.Te6edf3generatePacketIdTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3TelemetryTypeTb4b4b4.Te6edf3LOCAL_STATSTb4b4b4.Te6edf3ordinalTb4b4b4)

Te6edf3commandSenderTb4b4b4.Te6edf3requestTelemetryTb4b4b4(Te6edf3commandSenderTb4b4b4.Te6edf3generatePacketIdTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3TelemetryTypeTb4b4b4.Te6edf3DEVICETb4b4b4.Te6edf3ordinalTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffreportConnectionTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myNode Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3getMyNodeInfoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3radioModel Tff7b72= Te6edf3DataPairTb4b4b4(Te6edf3KEY_RADIO_MODELTb4b4b4, Te6edf3myNodeTff7b72?.Te6edf3model Tff7b72?: Ta5d6ff"Ta5d6ffunknownTa5d6ff"Tb4b4b4)

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(

Te6edf3EVENT_MESH_CONNECTTb4b4b4,

Te6edf3DataPairTb4b4b4(Te6edf3KEY_NUM_NODESTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4,

Te6edf3DataPairTb4b4b4(Te6edf3KEY_NUM_ONLINETb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3count Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3isOnline Tb4b4b4}Tb4b4b4)Tb4b4b4,

Te6edf3radioModelTb4b4b4,

Tb4b4b4)

T8b949e// DataDog RUM custom action matching Apple's "connect" event for cross-platform analytics.

Tff7b72val Te6edf3transportType Tff7b72= Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3getDeviceAddressTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3DeviceTypeTb4b4b4.Te6edf3fromAddressTb4b4b4(Tffa657itTb4b4b4)Tff7b72?.Te6edf3name Tb4b4b4}

Te6edf3analyticsTb4b4b4.Te6edf3trackConnectTb4b4b4(

Te6edf3firmwareVersion Tff7b72= Te6edf3myNodeTff7b72?.Te6edf3firmwareVersionTb4b4b4,

Te6edf3transportType Tff7b72= Te6edf3transportTypeTb4b4b4,

Te6edf3hardwareModel Tff7b72= Te6edf3myNodeTff7b72?.Te6edf3modelTb4b4b4,

Te6edf3nodes Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTb4b4b4.Te6edf3sizeTb4b4b4,

Te6edf3connectionRestored Tff7b72= Te6edf3connectionRestoredTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffupdateTelemetryTb4b4b4(Te6edf3tTb4b4b4: Te6edf3TelemetryTb4b4b4) Tb4b4b4{

Te6edf3tTb4b4b4.Te6edf3local_statsTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3updateLocalStatsTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4}

Te6edf3updateStatusNotificationTb4b4b4(Te6edf3tTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffupdateStatusNotificationTb4b4b4(Te6edf3telemetryTb4b4b4: Te6edf3Telemetry?Tb4b4b4) Tb4b4b4{

Te6edf3serviceNotificationsTb4b4b4.Te6edf3updateServiceStateNotificationTb4b4b4(

Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3telemetry Tff7b72= Te6edf3telemetryTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3DEVICE_SLEEP_TIMEOUT_SECONDS Tff7b72= T79c0ff3T79c0ff0

T8b949e// Maximum time (in seconds) to wait for a sleeping device before declaring it

T8b949e// disconnected, regardless of the device's ls_secs configuration. Without this

T8b949e// cap, routers (ls_secs=3600) leave the UI in DeviceSleep for over an hour.

Tff7b72private Tff7b72const Tff7b72val Te6edf3MAX_SLEEP_TIMEOUT_SECONDS Tff7b72= T79c0ff3T79c0ff0T79c0ff0

T8b949e/**

* Delay between the pre-handshake heartbeat and the want_config_id send.

*

* Ensures the heartbeat BLE write completes and the firmware's NimBLE callback context is warmed up before the

* config request arrives. 100ms is well above observed ESP32 task scheduling latency (~10–50ms) while adding

* negligible connection latency.

*/

Tff7b72private Tff7b72const Tff7b72val Te6edf3PRE_HANDSHAKE_SETTLE_MS Tff7b72= T79c0ff1T79c0ff0T79c0ff0L

Tff7b72private Tff7b72val Te6edf3HANDSHAKE_TIMEOUT_STAGE1 Tff7b72= T79c0ff3T79c0ff0.Te6edf3seconds

T8b949e/**

* Stage 2 drains the full node database, which can be significantly larger than Stage 1 config on big meshes.

* 60 s matches the meshtastic-client SDK timeout and avoids premature stall-guard triggers on meshes with 50+

* nodes.

*/

Tff7b72private Tff7b72val Te6edf3HANDSHAKE_TIMEOUT_STAGE2 Tff7b72= T79c0ff6T79c0ff0.Te6edf3seconds

T8b949e// Shorter window for the retry attempt: if the device genuinely didn't receive the

T8b949e// first want_config_id the retry completes within a few seconds. Waiting another 30s

T8b949e// before reconnecting just delays recovery unnecessarily.

Tff7b72private Tff7b72val Te6edf3HANDSHAKE_RETRY_TIMEOUT Tff7b72= T79c0ff1T79c0ff5.Te6edf3seconds

Tff7b72private Tff7b72const Tff7b72val Te6edf3EVENT_CONNECTED_SECONDS Tff7b72= Ta5d6ff"Ta5d6ffconnected_secondsTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3EVENT_MESH_DISCONNECT Tff7b72= Ta5d6ff"Ta5d6ffmesh_disconnectTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3EVENT_NUM_NODES Tff7b72= Ta5d6ff"Ta5d6ffnum_nodesTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3EVENT_MESH_CONNECT Tff7b72= Ta5d6ff"Ta5d6ffmesh_connectTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3KEY_NUM_NODES Tff7b72= Ta5d6ff"Ta5d6ffnum_nodesTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3KEY_NUM_ONLINE Tff7b72= Ta5d6ff"Ta5d6ffnum_onlineTa5d6ff"

Tff7b72private Tff7b72const Tff7b72val Te6edf3KEY_RADIO_MODEL Tff7b72= Ta5d6ff"Ta5d6ffradio_modelTa5d6ff"

Tb4b4b4}